# -*- coding: utf-8 -*-
#引入模块
import socket
import threading
import time

''' +++++++++++服务端程序+++++++++++ '''

#处理客户端的请求
def tcplink(sock,addr):
	print'Accept new connection from %s:%s...' % addr
	sock.send('Welcome!')
	
	while True:
		#接收缓冲区最大字节1024
		data=sock.recv(1024)
		time.sleep(1)
		#if data=='exit' or not data:
		#	break
		sock.send('Hello,%s!'%data)
		print'[client]:%s'%data
	sock.close()
	print 'Connection from %s:%s closed.'%addr

#创建socket
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#监听端口
s.bind(('127.0.0.1', 9998))
#可能是最大连接数
s.listen(5)
print 'Waiting for connection...'

while True:    
    #接受一个新连接
    sock,addr=s.accept()
    
    #创建新线程来处理TCP连接
    t=threading.Thread(target=tcplink(sock,addr))